#!/bin/bash
tables=(AML_ACCOUNT_MASTER AML_ALERT AML_CUSTOMER_MASTER AML_MONITORING_RULE AML_SCREENING_RESULT AML_SUSPICIOUS_TXN_REPORT AML_TRANSACTION_DETAIL AML_UBO_INFO AML_WATCHLIST_DETAIL AML_WATCHLIST_MASTER)
for i in "${tables[@]}"
do
	# 使用sqoop从Oracle导入数据到hive
	sqoop import \
	# 指定Oracle的jdbc连接地址
    --connect jdbc:oracle:thin:@192.168.88.149:1521:orcl \
    # 登录用户名：aml
    --username aml \
    # 登录密码：123456
    --password 123456 \
    # 字符串类型的空值null值处理，转换为hive空值的默认标识\N （N大写）
    --null-string '\\N' \
    # 非字符串类型的空值null值处理，转换为hive空值的默认标识\N
    --null-non-string '\\N' \
    # 导入Oracle表名，$i表示循环语句中变量表名
    --table "$i" \
    # 因为有分区，所以携程hcatalog，指定hive的数据库名
    --hcatalog-database ods \
    # 指定目标表名ods_变量表名
    --hcatalog-table "ods_$i" \
    # 指定hive分区字段名 etl_date
    --hive-partition-key "etl_date" \
    # 分区值当日-1，这个地方写死了2025-10-15
    --hive-partition-value "2025-10-15" \
	-m 1
	echo "步骤完成"
done